const mysql = require("mysql2")
const MySQLObj = {
    host: "localhost",
    user: "root",
    password: "123456",
    database: "vue_itbaizhan"
}

console.log('数据库配置信息：', MySQLObj);

const pool = mysql.createPool(MySQLObj);

// 监听连接池事件
pool.on('connection', function (connection) {
    console.log('新的数据库连接已创建');
});

pool.on('error', function (err) {
    console.error('数据库连接池错误：', err);
});

function SQLConnnect(sql, arr, callback) {
    console.log('执行SQL语句：', sql);
    console.log('SQL参数：', arr);

    pool.getConnection((err, connection) => {
        if (err) {
            console.error('获取数据库连接失败：', err);
            return;
        }
        console.log('成功获取数据库连接');

        connection.query(sql, arr, (err, result, fields) => {
            // 释放连接
            connection.release();
            if (err) {
                console.error('SQL执行错误：', err);
                return;
            }
            console.log('SQL执行成功，影响行数：', result.affectedRows || 0);
            console.log('查询结果：', result);
            callback(result)
        })
    })
}

module.exports = SQLConnnect